package com.study.mqtt.config;

import org.eclipse.paho.client.mqttv3.MqttMessage;

public interface MqttMessageConsumer {

	void consume(String topic, MqttMessage mqttMessage);
	
}
